package com.suxin.queue.batch;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingDeque;

/**
 * @author Tang
 * @classname PendingConstant
 * @description [ 延迟缓冲 pending 常量信息 ]
 * @date 2022/2/16 21:18
 */
public class PendingConstant {

    /**
     * 阻塞队列的大小
     */
    public static final Integer QUEUE_SIZE = 100;

    /**
     * 触发执行的数量阈值
     */
    public static final Integer NUM_THRESHOLD = 100;

    /**
     * 触发的时间阈值
     */
    public static final Long TIME_THRESHOLD = 1000L;


    /**
     * 消费者线程池的配置
     */
    public static final Integer CORE_SIZE = 2;

    public static final Integer MAX_SIZE = 2;

    public static final BlockingQueue BLOCKING_QUEUE = new LinkedBlockingDeque(5);


}